import pymysql
class Mysql():
    # 首先初始化数据链接数据库
    def __init__(self,host,user,password,database):
        self.con = pymysql.connect(host=host,user=user,password=password,database=database)
        # 建立游标
        self.cur = self.con.cursor()
    # 封装查询方法
    def query(self,sql):
        self.cur.execute(sql)
        return self.cur.fetchall()
    # 关闭
    def close(self):
        self.cur.close()
        self.con.close()